package com.xiaochong.bitong.api.utils;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.codec.digest.DigestUtils;
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.net.URL;
import java.net.URLConnection;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;
import java.util.Random;

/**
 * 网易易盾 验证码接口
 * 
 * @author admin
 *
 */
public class CaptchaKeyUtils {

	private final static Logger logger = LoggerFactory.getLogger(CaptchaKeyUtils.class);

	public static final String CAPTCHAID = "eed036d33c084ae3a09e1f0a37fc1506";

	public static final String SECRETID = "4826c6cdd63e8fd437f659c0e1e1f19b";
	
	public static final String SECRETKEY = "268fa6396e5c35279dea2fb3cb4f3d4a";
	public static final String URL = "http://c.dun.163yun.com/api/v2/verify";

	/**
	 * @param validate
	 * @return true 校验通过 false 校验不通过
	 */
	public static boolean sendCode(String validate) {
		Map<String, String> params = new HashMap<>(9);
		// 验证码id
		params.put("captchaId", CAPTCHAID);
		// 提交二次校验的验证数据，即NECaptchaValidate值
		params.put("validate", validate);
		// 用户信息，值可为空
		params.put("user", "");
		// 密钥对id
		params.put("secretId", SECRETID);
		// 版本信息，固定值v2
		params.put("version", "v2");
		// 当前时间戳的毫秒值，例1480395193000
		params.put("timestamp", String.valueOf(System.currentTimeMillis()));
		// 随机正整数，与 timestamp 联合起来，用于防止重放攻击
		params.put("nonce", String.valueOf(new Random().nextInt(10) + 1));
		String signature;
		try {
			signature = genSignature(SECRETKEY, params);
		} catch (UnsupportedEncodingException e) {
			logger.error("易盾签名出错：", e);
			return false;
		}
		// 签名信息，见签名计算
		params.put("signature", signature);
		try {
			logger.info("#####请求易盾参数:{}", params);
			String result = sendPost(URL, params);
			if (StringUtils.isEmpty(result)) {
				return false;
			}
			logger.info("请求网易验证码校验接口 result:[{}];", result);
			JSONObject obj = JSON.parseObject(result);
			return obj.getBooleanValue("result") || "OK".equals(obj.getString("msg"));
		} catch (Exception e) {
			logger.error("调用易盾出错：", e);
		}
		return false;
	}

	/**
	 * 向指定 URL 发送POST方法的请求
	 * 
	 * @param url
	 *            发送请求的 URL 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
	 * @return 所代表远程资源的响应结果
	 */
	public static String sendPost(String url, Map<String, String> params) {
		PrintWriter out = null;
		BufferedReader in = null;
		String result = "";

		StringBuffer sb = new StringBuffer();
		for (String param : params.keySet()) {
			sb.append(param + "=" + params.get(param) + "&");
		}
		String tempStr = sb.toString();
		tempStr = tempStr.substring(0, tempStr.length() - 1);
		try {
			URL realUrl = new URL(url);
			// 打开和URL之间的连接
			URLConnection conn = realUrl.openConnection();
			// 设置通用的请求属性
			conn.setRequestProperty("accept", "*/*");
			conn.setRequestProperty("connection", "Keep-Alive");
			// conn.setRequestProperty("user-agent","Mozilla/4.0 (compatible; MSIE 6.0;
			// Windows NT 5.1;SV1)");
			conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
			// 发送POST请求必须设置如下两行
			conn.setDoOutput(true);
			conn.setDoInput(true);
			// 获取URLConnection对象对应的输出流
			out = new PrintWriter(conn.getOutputStream());
			// 发送请求参数
			out.print(tempStr.toString());
			// flush输出流的缓冲
			out.flush();
			// 定义BufferedReader输入流来读取URL的响应
			in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
			String line;
			while ((line = in.readLine()) != null) {
				result += line;
			}
		} catch (Exception e) {
			System.out.println("发送 POST 请求出现异常！" + e);
			e.printStackTrace();
		}
		// 使用finally块来关闭输出流、输入流
		finally {
			try {
				if (out != null) {
					out.close();
				}
				if (in != null) {
					in.close();
				}
			} catch (IOException ex) {
				ex.printStackTrace();
			}
		}
		return result;
	}

	/**
	 * 生成签名信息
	 * 
	 * @param secretKey
	 *            产品私钥
	 * @param params
	 *            接口请求参数名和参数值map，不包括signature参数名
	 * @return
	 * @throws UnsupportedEncodingException
	 */
	public static String genSignature(String secretKey, Map<String, String> params)
			throws UnsupportedEncodingException {
		// 1. 参数名按照ASCII码表升序排序
		String[] keys = params.keySet().toArray(new String[0]);
		Arrays.sort(keys);

		// 2. 按照排序拼接参数名与参数值
		StringBuffer paramBuffer = new StringBuffer();
		for (String key : keys) {
			paramBuffer.append(key).append(params.get(key) == null ? "" : params.get(key));
		}
		// 3. 将secretKey拼接到最后
		paramBuffer.append(secretKey);

		// 4. MD5是128位长度的摘要算法，用16进制表示，一个十六进制的字符能表示4个位，所以签名后的字符串长度固定为32个十六进制字符。
		return DigestUtils.md5Hex(paramBuffer.toString().getBytes("utf-8"));
	}
}
